package com.exam.base.dao;

import java.io.Serializable;
import java.sql.SQLException;
import java.util.Collection;
import java.util.List;

import org.apache.log4j.Logger;
import org.hibernate.HibernateException;
import org.hibernate.Query;
import org.hibernate.Session;
import org.springframework.orm.hibernate3.HibernateCallback;
import org.springframework.orm.hibernate3.support.HibernateDaoSupport;

import com.exam.util.GenericsUtils;
import com.exam.util.Pagetools;

@SuppressWarnings("unchecked")
public class BaseDao<E> extends HibernateDaoSupport {

	/**
	 * 使用hql语句进行分页查询
	 * 
	 * @param hql
	 *            需要查询的hql语句
	 * @param offset
	 *            第一条记录索引
	 * @param pageSize
	 *            每页需要显示的记录数
	 * @return 当前页的所有记录
	 */
	private List findByPage(final String hql, final int offset,
			final int pageSize) {
		// 通过一个HibernateCallback对象来执行查询
		List list = getHibernateTemplate().executeFind(new HibernateCallback() {
			// 实现HibernateCallback接口必须实现的方法
			public Object doInHibernate(Session session)
					throws HibernateException, SQLException {
				// 执行Hibernate分页查询
				List result = session.createQuery(hql).setFirstResult(offset)
						.setMaxResults(pageSize).list();
				return result;
			}
		});
		return list;
	}

	/**
	 * 使用hql语句进行分页查询
	 * 
	 * @param hql
	 *            需要查询的hql语句
	 * @param value
	 *            如果hql有一个参数需要传入，value就是传入hql语句的参数
	 * @param offset
	 *            第一条记录索引
	 * @param pageSize
	 *            每页需要显示的记录数
	 * @return 当前页的所有记录
	 */
	private List findByPage(final String hql, final Object value,
			final int offset, final int pageSize) {
		// 通过一个HibernateCallback对象来执行查询
		List list = getHibernateTemplate().executeFind(new HibernateCallback() {
			// 实现HibernateCallback接口必须实现的方法
			public Object doInHibernate(Session session)
					throws HibernateException, SQLException {
				// 执行Hibernate分页查询
				List result = session.createQuery(hql)
						// 为hql语句传入参数
						.setParameter(0, value).setFirstResult(offset)
						.setMaxResults(pageSize).list();
				return result;
			}
		});
		return list;
	}

	/**
	 * 使用hql语句进行分页查询
	 * 
	 * @param hql
	 *            需要查询的hql语句
	 * @param values
	 *            如果hql有多个个参数需要传入，values就是传入hql的参数数组
	 * @param offset
	 *            第一条记录索引
	 * @param pageSize
	 *            每页需要显示的记录数
	 * @return 当前页的所有记录
	 */
	private List findByPage(final String hql, final Object[] values,
			final int offset, final int pageSize) {
		// 通过一个HibernateCallback对象来执行查询
		List list = getHibernateTemplate().executeFind(new HibernateCallback() {
			// 实现HibernateCallback接口必须实现的方法
			public Object doInHibernate(Session session)
					throws HibernateException, SQLException {
				// 执行Hibernate分页查询
				Query query = session.createQuery(hql);
				// 为hql语句传入参数
				for (int i = 0; i < values.length; i++) {
					query.setParameter(i, values[i]);
				}
				List result = query.setFirstResult(offset).setMaxResults(
						pageSize).list();
				return result;
			}
		});
		return list;
	}

	public List findByPage(final String hql, final Object[] values,
			final Pagetools page) {
		return findByPage(hql, values, page.getOffset(), page.getPageSize());
	}

	public List findByPage(final String hql, final Pagetools page) {
		return findByPage(hql, page.getOffset(), page.getPageSize());
	}

	public List findByHql(final String hql, final Object[] values) {
		// 通过一个HibernateCallback对象来执行查询
		List list = getHibernateTemplate().executeFind(new HibernateCallback() {
			// 实现HibernateCallback接口必须实现的方法
			public Object doInHibernate(Session session)
					throws HibernateException, SQLException {
				// 执行Hibernate分页查询
				Query query = session.createQuery(hql);
				// 为hql语句传入参数
				for (int i = 0; i < values.length; i++) {
					query.setParameter(i, values[i]);
				}
				List result = query.list();
				return result;
			}
		});
		return list;
	}

	public List findByHql(final String hql) {
		// 通过一个HibernateCallback对象来执行查询
		List list = getHibernateTemplate().executeFind(new HibernateCallback() {
			// 实现HibernateCallback接口必须实现的方法
			public Object doInHibernate(Session session)
					throws HibernateException, SQLException {
				// 执行Hibernate分页查询
				Query query = session.createQuery(hql);
				List result = query.list();
				return result;
			}
		});
		return list;
	}

	/**
	 * 系统运行日志.
	 */
	protected final Logger logger = Logger.getLogger(getClass());

	/**
	 * Dao所管理的Entity类型.
	 */
	protected Class entityClass;

	/**
	 * 取得entityClass的函数.不支持泛型的子类可以抛开Class entityClass, 重新实现此函数达到相同效果.
	 * 
	 * @return 实体类
	 */
	protected Class getEntityClass() {
		return entityClass;
	}

	/**
	 * 通过构造函数对entityClass付值.
	 */
	public BaseDao() {
		this.entityClass = GenericsUtils.getGenericClass(getClass());
	}

	/**
	 * 通过对象的序列id获取实体实例.
	 * 
	 * @param id
	 *            对象的序列id
	 * @return 实体实例
	 */
	@SuppressWarnings("unchecked")
	public E get(Serializable id) {
		return (E) getHibernateTemplate().get(entityClass, id);
	}

	public Object getById(Class cls, Serializable id) {
		return getHibernateTemplate().get(cls, id);
	}

	/**
	 * 获取实体所有实例.
	 * 
	 * @return 实体实例列表
	 */
	@SuppressWarnings("unchecked")
	public List<E> list() {
		return getHibernateTemplate().loadAll(entityClass);
	}

	/**
	 * 新增一条实体实例.
	 * 
	 * @param o
	 *            实体实例
	 * @return 序列化ID
	 */
	public Serializable create(Object o) {
		return super.getHibernateTemplate().save(o);
	}

	/**
	 * 修改实体实例.
	 * 
	 * @param o
	 *            实体实例
	 */
	public void update(Object o) {
		super.getHibernateTemplate().update(o);
	}

	/**
	 * 新增或修改一条实体实例.
	 * 
	 * @param o
	 *            实体实例
	 */
	public void save(Object o) {
		getHibernateTemplate().saveOrUpdate(o);
	}

	public void saveAll(Collection c) {
		getHibernateTemplate().saveOrUpdateAll(c);
	}

	public void deleteAll(Collection c) {
		getHibernateTemplate().deleteAll(c);
	}

	/**
	 * 合并方式，新增或修改一条实体实例.
	 * 
	 * @param o
	 *            实体实例
	 */
	public void saveMerge(Object o) {
		getHibernateTemplate().merge(o);
	}

	/**
	 * 删除实体实例.
	 * 
	 * @param o
	 *            实体实例
	 */
	public void remove(Object o) {
		getHibernateTemplate().delete(o);
	}

	/**
	 * 通过id删除实体实例.
	 * 
	 * @param id
	 *            实体实例的id
	 */
	public void removeById(Serializable id) {
		remove(get(id));
	}
}
